/**
 * @author taowei20061122@163.com
 *
 * 2013-8-6 下午09:03:32
 */
package etl.db;

import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.concurrent.Callable;

import org.apache.log4j.Logger;

/**
 * @author taowei20061122@163.com
 *
 * 2013-8-6 下午09:03:32
 */
public class ExcuteUpdateCallable implements Callable {
	private static final Logger logger = Logger.getLogger(ExcuteUpdateCallable.class);
	PreparedStatement pstmt = null;
	

	public ExcuteUpdateCallable(PreparedStatement _pstmt) {
		super();
		this.pstmt = _pstmt;
	}

	@Override
	public Object call() throws SQLException {
		try {
			this.pstmt.executeUpdate();
		} catch (SQLException e) {
			logger.error("",e);
			throw e;
		}
		return true;
	}
}
